package com.yiyuan.app.service;

import com.yiyuan.app.entity.po.GRecordMqttMessagePO;
import org.eclipse.paho.client.mqttv3.MqttException;

import java.io.IOException;

public interface MQTTService {
    /**
     * 处理投币回调
     *
     * @return
     */
    Boolean dealPushCoins(GRecordMqttMessagePO messagePO) throws MqttException;

    /**
     * 处理落币通知
     *
     * @return
     */
    Boolean dealPushCoinsResult(GRecordMqttMessagePO messagePO);

    /**
     * 处理中奖通知
     *
     * @return
     */
    Boolean dealPrizeResult(GRecordMqttMessagePO messagePO) throws IOException;

    /**
     * 处理机器状态通知
     *
     * @return
     */
    Boolean dealMachineStatus(GRecordMqttMessagePO messagePO) throws IOException;

    /**
     * 结算街机娱乐
     * @param messagePO
     * @return
     */
    Boolean dealMachineSettle(GRecordMqttMessagePO messagePO);
}
